package org.example.rabbitmq.concurrent.lock;

public interface RateLimiter {
    void acquire(String queueName) throws InterruptedException;

    void release(String queueName);

    void addQueueRateLimiter(String queueName);
}